package club.hicode.daydayup.rabbitmq.topic;

import club.hicode.daydayup.rabbitmq.MQConst;
import cn.hutool.json.JSONUtil;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * Topic 信息的发送器
 *
 * @author Liu Chunfu
 * @date 2018-05-08 上午10:25
 **/
@Component
public class TopicSender {

    @Autowired
    private AmqpTemplate amqpTemplatel;

    public void senderTopic(Object object) {
        //发送的第一个参数是 路由的 key,就是交给那个exchange 1个 exchange绑定了1个 topic
        //todo 此处的问题，为什么还需要 exchange 了？不是根据 key 已经绑定好了吗？是不是因为 topic的 k
        //其中 key支持简答的正则匹配
        amqpTemplatel.convertAndSend(MQConst.TOPIC_EXCHANGE, "mytopic.222", JSONUtil.toJsonStr(object));
    }
}
